package HandshakeJoin;

import java.util.List;
import org.apache.s4.base.Event;
import org.apache.s4.base.KeyFinder;
import com.google.common.collect.ImmutableList;

public class QueryRequestKeyFinder implements KeyFinder<Event>
{
    @Override
    public List<String> get(final Event req) {
        return ImmutableList.of(req.get("joinId"));
    }
}